package com.huatai.datacenter.entity.messagequeuemonitor;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

/**
 * 一个主题一个消费组一个分区下要输出的堆积消息
 *
 * @author lizhong
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
@ApiModel(value = "一条堆积消息返回类", description = "一条堆积消息返回类")
public class LagRecord {

	@ApiModelProperty("该条堆积消息的offset值")
	private Long offset; // 当前偏差

	@ApiModelProperty("该条堆积消息的时间")
	private Long timestamp; // 时间戳可以指示消息产生的时间，也可以是在消息进入 Kafka 的时间，毫秒
//
//	private TimestampType timestampType; // TimestampType.CREATE_TIME或者TimestampType.LOG_APPEND_TIME
//
//	private String key; // key

	@ApiModelProperty("该条堆积消息的具体内容")
	private String value; // 该消息的具体内容
}
